package com.titan.single.vo;

import lombok.Data;

import java.util.List;

/**
 * 接收的canal kafka通用数据结构
 **/
@Data
public class CanalCommon<T> {
    // 操作后 目前最新的表数据, 可通过JsonUtils.stringToObj转成表对应的实体类
    private List<T> data;
    // 数据库名
    private String database;
    private Long es;
    private String gtid;
    private Long id;
    private Boolean isDdl;
    private Object mysqlType;
    // 更新操作才有的,数据库表老字段数据, 可通过JsonUtils.stringToObj转成表对应的实体类
    private List<T> old;
    private List<String> pkNames;
    private String sql;
    private Object sqlType;
    private String table;
    private Long ts;
    // 操作类型 新增:"INSERT" ,删除:"DELETE" , 更新:"UPDATE"
    private String type;
}